package com.lost.octopus.es.processor.mq.consumer.capture;

import com.lost.octopus.es.processor.mq.consumer.dto.ChangeDataCaptureInfo;

import static org.apache.log4j.Logger.getLogger;

/**
 * 数据捕获并处理到es
 * @author zhangbh
 * @date 2025/4/23 9:49
 */
public interface DataCaptureDeal {

    /**
     * 支持处理的表
     */
    String acceptTable();

    /**
     * 处理的方案
     */
    String acceptSchema();

    /**
     * 主表数据被删除的处理
     */
    default boolean acceptDelete(ChangeDataCaptureInfo data) {
        // "目前不会删除，暂时不处理"
        getLogger(DataCaptureDeal.class).warn(acceptSchema() + "." + "目前删除暂时不处理");
        return true;
    }

}
